package com.scorpio.consumer.service;

import com.scorpio.mqtt.constant.MQConstant;
import com.scorpio.order.service.OrderService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener;

public class NotifyConsumerService {

    @Autowired
    private OrderService orderService;

    @JmsListener(destination = MQConstant.ORDER_OVERDUE)
    public void pushOrderOverdue(String data) {
        orderService.updateLoseEfficacy(data);
    }

}
